prometheus-http-query

This crate provides an interface to the Prometheus HTTP API and leverage Rust's type system in the process where applicable.

Example

use prometheus_http_query::{Client, Error, Selector, RuleType};

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), Error> {
    let client = Client::default();

    // Evaluate a PromQL query.
    let q = "topk by (code) (5, prometheus_http_requests_total)";
    let response = client.query(q, None, None).await?;
    assert!(response.as_instant().is_some());

    // Retrieve active alerts.
    let alerts = client.alerts().await();
    assert!(response.is_ok());

    // Retrieve recording rules.
    let recording_rules = client.rules(Some(RuleType::Record)).await;
    assert!(recording_rules.is_ok());

    // Retrieve time series metadata.
    let select1 = Selector::new()
        .eq("handler", "/api/v1/query");

    let select2 = Selector::new()
        .eq("job", "node")
        .regex_eq("mode", ".+");

    let time_series = client.series(&[select1, select2], None, None).await;
    assert!(time_series.is_ok());

    Ok(())
}

Compatibility

This library is compatible with all Prometheus versions starting from v2.30. Individual client methods might fail with older versions.

Tests

In order to run all tests a Prometheus server must be running at http://localhost:9090. No special configuration is required at this point.

Run: RUSTFLAGS="--cfg unsound_local_offset" cargo test

Contributing

Please do not hesitate to file issues in order to report bugs, ask questions or make suggestions. You are also welcome to tackle open issues if there are any.

If you are looking to submit code, please make sure that the tests pass successfully.